package com.gabry.flink

import org.apache.flink.streaming.api.scala.async.{AsyncFunction, ResultFuture}

class MySource extends AsyncFunction[String,String]{
  override def asyncInvoke(input: String, resultFuture: ResultFuture[String]): Unit = {
  }
}
